ba547aa33ea6a0002e104b38e15e0555af4853ce,core/server/src/main/java/alluxio/worker/netty/NettyDataServer.java,NettyDataServer,close,#,65
Before Change
int timeoutSecs = Configuration.getInt(PropertyKey.WORKER_NETWORK_NETTY_SHUTDOWN_TIMEOUT);
mChannelFuture.channel().close().awaitUninterruptibly(timeoutSecs, TimeUnit.SECONDS);
mBootstrap.group().shutdownGracefully(quietPeriodSecs, timeoutSecs, TimeUnit.SECONDS)
.awaitUninterruptibly(timeoutSecs, TimeUnit.SECONDS);
mBootstrap.childGroup().shutdownGracefully(quietPeriodSecs, timeoutSecs, TimeUnit.SECONDS)
.awaitUninterruptibly(timeoutSecs, TimeUnit.SECONDS);
}
After Change
if (!completed) {
LOG.warn("Closing the channel timed out.");
}
completed =
mBootstrap.group().shutdownGracefully(quietPeriodSecs, timeoutSecs, TimeUnit.SECONDS)
.awaitUninterruptibly(timeoutSecs, TimeUnit.SECONDS);
if (!completed) {
LOG.warn("Forced group shutdown because graceful shutdown timed out.");
}
completed =
mBootstrap.childGroup().shutdownGracefully(quietPeriodSecs, timeoutSecs, TimeUnit.SECONDS)